package conf

import (
	"encoding/json"
	"io/ioutil"
	"ycxp/ysjzx/log"
)

var MqConf struct {
	AmqpUrl       string //amqp地址
	ConnectionNum int    //连接数
	ChannelNum    int    //每个连接的channel数量

	//ExchangeList []ysmq.ExchangeInfo
	//QueueList    []ysmq.QueueInfo
}

//// 定义队列交换机对象
//type QueueExchange struct {
//	QueueName    string // 队列名称
//	RoutingKey   string // key名称
//	ExchangeName string // 交换机名称
//	//ExchangeType string // 交换机类型
//}

func init() {
	log.Release("mq conf begin")
	data, err := ioutil.ReadFile("E:/workspace/gitee/ycxp/mq/conf/server.json")
	log.Release("mq conf end")
	if err != nil {
		log.Fatal("%v", err)
	}
	err = json.Unmarshal(data, &MqConf)
	if err != nil {
		log.Fatal("%v", err)
	}
}
